package com.sky.business.sys.handler;

/**
 * mqtt事件处理器
 */
public interface MqttEventHandler {
    /**
     * 是否与当前的处理器相匹配
     * @param topic 主题
     * @param msg 消息
     * @param event 事件
     * @return 是否匹配
     */
    boolean match(String topic,String msg,String event);


    /**
     * 解析事件
     * @param topic 主题
     * @param msg 消息
     * @throws Exception 处理过程中的异常
     */
    void  handle(String topic, String msg) throws Exception;
}
